package org.rency.mq.kafka.consumer.handler;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;

/**
 * 消费者处理器
 *
 * @author: Created by user_rcy@163.com on 2016/10/14.
 * @version: V1.0.0
 * @since JDK 1.8
 */
public interface MessageHandler<K, V> {

    /**
     * 消息处理
     * @param data
     */
    public void handler(ConsumerRecord<K, V> data);

    /**
     * 批量消息处理
     * @param datas
     */
    public void handler(List<ConsumerRecord<K, V>> datas);
}
